b75cbb99bb5ffe8253f94a69e420e2bb6c9fdcc8,raft-grpc/src/main/java/org/apache/raft/grpc/server/GRpcLogAppender.java,AppendLogResponseHandler,onError,#Throwable#,216

Before Change


     */
    @Override
    public void onError(Throwable t) {
      LOG.info("{} got error when appending entries to {}, exception: {}",
          server.getId(), follower.getPeer().getId(), t);
      // clear the pending requests queue and reset the next index of follower
      // TODO reuse the requests
      AppendEntriesRequestProto request = pendingRequests.peek();

After Change


        LOG.info("{} is stopped", GRpcLogAppender.this);
        return;
      }
      LOG.warn("{} got error when appending entries to {}, exception: {}.",
          server.getId(), follower.getPeer().getId(), t);

      synchronized (this) {
        if (Status.fromThrowable(t) == Status.UNKNOWN) {